package cn.itcast.flink.batch.task;

import cn.itcast.flink.batch.util.AnalysisDataRate;
import cn.itcast.flink.batch.util.DateUtil;

/**
 * Author itcast
 * 按天统计数据的质量
 */
public class TotalDataDayRateTask {
    public static void main(String[] args) {
        //获取当天时间 getTodayDate
        String day = DateUtil.getYearMonthDayDate();

        //String month = DateUtil.getYearMonthDate() + "00";
        //实例化 AnalysisDataRate(day)
        AnalysisDataRate analysisDataRate = new AnalysisDataRate(day);
        //执行任务
        analysisDataRate.executeTask();
    }
}
